package com.atguigu.func;

import com.atguigu.beans.WaterSensor;
import org.apache.flink.api.common.functions.MapFunction;

/**
 * @author Felix
 * @date 2024/2/20
 */
public class MyMapFunction implements MapFunction<WaterSensor,String> {
    @Override
    public String map(WaterSensor ws) throws Exception {
        return ws.id;
    }
}
